package com.jkgl.controller;

import com.jkgl.common.core.domain.R;
import com.jkgl.common.utils.SecurityUtils;
import com.jkgl.model.socket.MessageVO;
import com.jkgl.socket.NoticeSocket;
import lombok.RequiredArgsConstructor;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("message")
@RequiredArgsConstructor
public class SocketMessageController {
    private final NoticeSocket socket;
    private final RedisTemplate redisTemplate;

//    @GetMapping
//    public R list(){
//
//    }



    @PostMapping("onlineBroadCasting")
    public R onlineBroadcasting(@RequestBody MessageVO vo){
        if(SecurityUtils.getUserId() != 1L){
            return R.fail("仅为管理员可以发送广播");
        }
//        redisTemplate.opsForList().
        socket.sendMessage(vo);
        return R.ok("发送成功");
    }

}
